package com.lfd.kafka.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

/**
 * @项目名： spring-emq
 * @包名： com.lfd.kafka.service
 * @文件名: KafKaProducer
 * @创建者: liufudong@szyh-smart.com
 * @创建时间: 2024/9/30 16:39
 * @描述：创建 Kafka 生产者 创建一个 Kafka 生产者类，用于发送消息：
 */
@Service
public class KafkaProducer {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void send(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}
